package com.spc.demo.exceptionhandle;

import com.spc.demo.constant.Constant;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

/**
 * @author pingchao.su
 * @date 2022/7/12 21:36
 */
public class HandleSerial {
    // handle系列的方法有返回值
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // handle系列成功处理方法，异步，使用同一线程，返回任意类型
        // 会等上一个任务结束
        CompletableFuture<Integer> first=Constant.cf.handle((result, e) -> {
            System.out.println("接收到任务返回值:"+result);
            if (e != null) {
                System.out.println("异常发生");
            }
            return 1;
        });
        System.out.println(first.get());
    }
}
